google.golang.org/grpc/internal/balancer/gracefulswitch.balancerWrapper.gsb (field)

30 uses

	google.golang.org/grpc/internal/balancer/gracefulswitch (current package)
		gracefulswitch.go#L114: 		gsb:        gsb,
		gracefulswitch.go#L291: 	gsb     *Balancer
		gracefulswitch.go#L312: 	bw.gsb.mu.Lock()
		gracefulswitch.go#L316: 	bw.gsb.mu.Unlock()
		gracefulswitch.go#L323: 	bw.gsb.mu.Lock()
		gracefulswitch.go#L324: 	defer bw.gsb.mu.Unlock()
		gracefulswitch.go#L327: 	if !bw.gsb.balancerCurrentOrPending(bw) {
		gracefulswitch.go#L331: 	if bw == bw.gsb.balancerCurrent {
		gracefulswitch.go#L337: 		if state.ConnectivityState != connectivity.Ready && bw.gsb.balancerPending != nil {
		gracefulswitch.go#L338: 			bw.gsb.swap()
		gracefulswitch.go#L347: 		bw.gsb.cc.UpdateState(state)
		gracefulswitch.go#L355: 	if state.ConnectivityState != connectivity.Connecting || bw.gsb.balancerCurrent.lastState.ConnectivityState != connectivity.Ready {
		gracefulswitch.go#L356: 		bw.gsb.swap()
		gracefulswitch.go#L361: 	bw.gsb.mu.Lock()
		gracefulswitch.go#L362: 	if !bw.gsb.balancerCurrentOrPending(bw) {
		gracefulswitch.go#L363: 		bw.gsb.mu.Unlock()
		gracefulswitch.go#L366: 	bw.gsb.mu.Unlock()
		gracefulswitch.go#L370: 	opts.StateListener = func(state balancer.SubConnState) { bw.gsb.updateSubConnState(sc, state, oldListener) }
		gracefulswitch.go#L371: 	sc, err := bw.gsb.cc.NewSubConn(addrs, opts)
		gracefulswitch.go#L375: 	bw.gsb.mu.Lock()
		gracefulswitch.go#L376: 	if !bw.gsb.balancerCurrentOrPending(bw) { // balancer was closed during this call
		gracefulswitch.go#L378: 		bw.gsb.mu.Unlock()
		gracefulswitch.go#L382: 	bw.gsb.mu.Unlock()
		gracefulswitch.go#L389: 	if bw != bw.gsb.latestBalancer() {
		gracefulswitch.go#L392: 	bw.gsb.cc.ResolveNow(opts)
		gracefulswitch.go#L402: 	bw.gsb.mu.Lock()
		gracefulswitch.go#L403: 	if !bw.gsb.balancerCurrentOrPending(bw) {
		gracefulswitch.go#L404: 		bw.gsb.mu.Unlock()
		gracefulswitch.go#L407: 	bw.gsb.mu.Unlock()
		gracefulswitch.go#L408: 	bw.gsb.cc.UpdateAddresses(sc, addrs)